package com.basic.library.httpmanager.task;

import android.util.Base64;
import android.util.Log;

import androidx.databinding.Observable;

import com.basic.library.BuildConfig;
import com.basic.library.base.BaseApplication;
import com.basic.library.bean.HeaderInfo;
import com.basic.library.utils.JsonUtils;
import com.basic.library.utils.LocalData;
import com.zhouyou.http.EasyHttp;
import com.zhouyou.http.cache.converter.SerializableDiskConverter;
import com.zhouyou.http.cache.model.CacheMode;
import com.zhouyou.http.cookie.CookieManger;
import com.zhouyou.http.model.HttpParams;

import java.io.IOException;

import okhttp3.Interceptor;
import okhttp3.Request;
import okhttp3.Response;

/**
 * @author yj
 * @description
 */
public class RxEasyHttpConfig {

    public static void initConfig() {        //全局设置请求头
//        HttpHeaders headers = new HttpHeaders();
//        headers.put("Custom", getHeaderStr());
        //全局设置请求参数
        HttpParams params = new HttpParams();
        params.put("appId", "");

        //以下设置的所有参数是全局参数,同样的参数可以在请求的时候再设置一遍,那么对于该请求来讲,请求中的参数会覆盖全局参数
        EasyHttp.getInstance()

                //可以全局统一设置全局URL
                .setBaseUrl(ApiHttpService.BASE_URL)//设置全局URL

                // 打开该调试开关并设置TAG,不需要就不要加入该行
                // 最后的true表示是否打印okgo的内部异常，一般打开方便调试错误
                .debug("EasyHttp", BuildConfig.DEBUG)

                //如果使用默认的60秒,以下三行也不需要设置
                .setReadTimeOut(30 * 1000)
                .setWriteTimeOut(30 * 100)
                .setConnectTimeout(30 * 100)

                //可以全局统一设置超时重连次数,默认为3次,那么最差的情况会请求4次(一次原始请求,三次重连请求),
                //不需要可以设置为0
                .setRetryCount(2)//网络不好自动重试3次
                //可以全局统一设置超时重试间隔时间,默认为500ms,不需要可以设置为0
                .setRetryDelay(500)//每次延时500ms重试
                //可以全局统一设置超时重试间隔叠加时间,默认为0ms不叠加
                .setRetryIncreaseDelay(500)//每次延时叠加500ms

                //可以全局统一设置缓存模式,默认是不使用缓存,可以不传,具体请看CacheMode
                .setCacheMode(CacheMode.NO_CACHE)
                //可以全局统一设置缓存时间,默认永不过期
                .setCacheTime(-1)//-1表示永久缓存,单位:秒 ，Okhttp和自定义RxCache缓存都起作用
                //全局设置自定义缓存保存转换器，主要针对自定义RxCache缓存
                .setCacheDiskConverter(new SerializableDiskConverter())//默认缓存使用序列化转化
                //全局设置自定义缓存大小，默认50M
                .setCacheMaxSize(100 * 1024 * 1024)//设置缓存大小为100M
                //设置缓存版本，如果缓存有变化，修改版本后，缓存就不会被加载。特别是用于版本重大升级时缓存不能使用的情况
                .setCacheVersion(1)//缓存版本为1
                //.setHttpCache(new Cache())//设置Okhttp缓存，在缓存模式为DEFAULT才起作用

                //可以设置https的证书,以下几种方案根据需要自己设置
//                .setCertificates()                                  //方法一：信任所有证书,不安全有风险
//                .setCertificates(new SafeTrustManager())            //方法二：自定义信任规则，校验服务端证书
//        配置https的域名匹配规则，不需要就不要加入，使用不当会导致https握手失败
//                .setHostnameVerifier(new SafeHostnameVerifier())
//                .addConverterFactory(GsonConverterFactory.create(gson))//本框架没有采用Retrofit的Gson转化，所以不用配置
//                .addCommonHeaders(headers)//设置全局公共头 (token 变了 就要重设了)
//                .addCommonParams(params)//设置全局公共参数
//                .addNetworkInterceptor(new NoCacheInterceptor())//设置网络拦截器
//                .setCallFactory()//局设置Retrofit对象Factory
                .setCookieStore(new CookieManger(BaseApplication.getInstance()))//设置cookie
//                .setOkproxy()//设置全局代理
//                .setOkconnectionPool()//设置请求连接池
//                .setCallbackExecutor()//全局设置Retrofit callbackExecutor
//        可以添加全局拦截器，不需要就不要加入，错误写法直接导致任何回调不执行
//                .addInterceptor(new GzipRequestInterceptor())//开启post数据进行gzip后发送给服务器
//                .addInterceptor(new CustomSignInterceptor())//添加参数签名拦截器
                .addInterceptor(new Interceptor() {
                    @Override
                    public Response intercept(Chain chain) throws IOException {
                        Request originalRequest = chain.request();
                        // get new request, add request header
                        Request updateRequest = originalRequest.newBuilder()
                                .header("Custom", getHeaderStr())
                                .build();
                        return chain.proceed(updateRequest);
                    }
                })
        ;
    }

    static String base64;
    static String headerStr;
    public static String CacheCookieKey;

    private static String getHeaderStr() {
        if (base64 == null) {
            HeaderInfo headerInfo = new HeaderInfo();
            if (LocalData.getInstance().isLogin()) {
                headerInfo.setToken(LocalData.getInstance().getUserInfo().getToken());
                headerInfo.setUserId(LocalData.getInstance().getUserInfo().getId() + "");
            }
            headerStr = JsonUtils.toJson(headerInfo);
            base64 = Base64.encodeToString(headerStr.getBytes(), Base64.NO_WRAP);
            CacheCookieKey = headerInfo.getUserId() + ""; //账号对应的唯一不变值
            LocalData.getInstance().user.addOnPropertyChangedCallback(new Observable.OnPropertyChangedCallback() {
                @Override
                public void onPropertyChanged(Observable sender, int propertyId) {
                    base64 = null;
                    HeaderInfo headerInfo = new HeaderInfo();
                    if (LocalData.getInstance().isLogin()) {
                        headerInfo.setToken(LocalData.getInstance().getUserInfo().getToken());
                        headerInfo.setUserId(LocalData.getInstance().getUserInfo().getId() + "");
                    }
                    headerStr = JsonUtils.toJson(headerInfo);
                    base64 = Base64.encodeToString(headerStr.getBytes(), Base64.NO_WRAP);
                    CacheCookieKey = headerInfo.getUserId() + ""; //账号对应的唯一不变值
                }
            });
        }
        if (BuildConfig.DEBUG) {
            Log.d("EasyHttp-header", headerStr);
            Log.d("EasyHttp-header-64", base64);
        }
        return base64;
    }
}
